package com.atguigu.gmall.activity.config;

import com.atguigu.gmall.activity.utils.CacheHelper;
import org.springframework.stereotype.Component;

/**
 * @Author: lx
 * @Time: 14:39
 * @Description:
 * 自定义对象
 *    监听Redis的队列的名称 从队列获取出消息之后 由当前自定义的对象 对消息进行处理
 *
 */
@Component
public class MessageReceive {

    //接收消息的方法
    public void receiveMessage(String message){
        // skuId:1
        System.out.println("Redis的发布订阅消息：" + message);
        //  "30:1"  改为 30:1
        message = message.replaceAll("\"","");
        //保存在内存
        String[] m = message.split(":");
        //设置进咱们的缓存
        CacheHelper.put(m[0],m[1]);

    }
}
